ingest data in snowflake warehouse using pyspark